from celery import Celery

# 由于发送email时是用来配置里面的变量,所以需要设置Django运行所依赖的环境变量
import os
if not os.environ.get("DJANGO_SETTINGS_MODULE"):
    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")
# 创建Celery类实例对象
celery_app = Celery('celery_tasks')


# 加载配置 (由于启动worker时必须退到main上一级的目录外面,所以路径就从celery_tasks开始)
celery_app.config_from_object('celery_tasks.config')


# celery worker 启动时自动发现任务函数
celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email', 'celery_tasks.html'])